package com.xian.im.message.producer;

import com.xian.im.common.model.session.SessionUser;
import com.xian.im.message.model.QueueMsg;
import io.netty.channel.ChannelHandlerContext;

/**
 * @program: xian-im-server
 * @description:  生产消息接口
 * @author: liru.xian
 * @create: 2021-03-01 09:35
 **/
public interface MessageProducer {

    /**
     * ss
     * @param message 消息体
     * @param session 发送者信息
     * @param ctx 发送者ctx连接
     */
    void doHandler(QueueMsg message, SessionUser session, ChannelHandlerContext ctx);
    /**
     *
     * @return
     */
    Integer getType();
}
